//package com.wj.opratorlog.utils;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.context.annotation.Bean;
//import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
//import org.springframework.stereotype.Component;
//
//import java.util.concurrent.ArrayBlockingQueue;
//import java.util.concurrent.ThreadPoolExecutor;
//
///**
// * @author cnry
// * @date 2024/6/27
// * @description
// **/
//
//@Component
//@Slf4j
//public class CustomerThreadPool {
//@Bean("customerThreadPoolTaskExecutor")
//public   ThreadPoolTaskExecutor  getThreadPool() {
//    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//    //配置核心线程数
//    executor.setCorePoolSize(1);
//    //配置最大线程数
//    executor.setMaxPoolSize(2);
//    //配置队列大小
//    executor.setQueueCapacity(1);
//    //配置线程池中的线程的名称前缀
//
//    // rejection-policy：当pool已经达到max size的时候，如何处理新任务
//    // CALLER_RUNS：不在新线程中执行任务，而是有调用者所在的线程来执行
//    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
//
//    //增加MDC的线程池修饰类
//    executor.setTaskDecorator(new MDCTaskDecorator());
//    //执行初始化
//    executor.initialize();
//    log.info("end asyncServiceExecutor------------");
//    return executor;
//}
//
//}
